// 数据库的连接
const mysql = require('mysql')
// 从全局引入数据库连接部分
const { dbConfig } = require('../../config')
// 连接
const pool = mysql.createPool(dbConfig)

let db = {}

db.query = function (sql, params) {
  return new Promise((resolve, reject) => {
    // 取链接
    pool.getConnection((err, connection) => {
      if (err) {
        reject(err)
        return
      }

      connection.query(sql, params, (err, result) => {
        console.log(`${sql}=>${params}`)
        // 释放链接
        connection.release()
        if (err) {
          reject(err)
          return
        }
        resolve(result)
      })
    })
  })
}

module.exports = db
